using Grand.Business.Core.Interfaces.Cms;
using Grand.Business.Core.Interfaces.Common.Security;
using Grand.Data;
using Grand.Domain.Customers;
using Grand.Domain.Pages;
using Grand.Infrastructure;
using Grand.Infrastructure.Caching;
using Grand.Infrastructure.Caching.Constants;
using Grand.Infrastructure.Configuration;
using Grand.Infrastructure.Extensions;
using MediatR;

namespace Grand.Business.Cms.Services;

/// <summary>
///     Page service
/// </summary>
public class PageService : IPageService
{
    #region Ctor

    public PageService(IRepository<Page> pageRepository,
        IWorkContextAccessor workContextAccessor,
        IAclService aclService,
        IMediator mediator,
        ICacheBase cacheBase, AccessControlConfig accessControlConfig)
    {
        _pageRepository = pageRepository;
        _workContextAccessor = workContextAccessor;
        _aclService = aclService;
        _mediator = mediator;
        _cacheBase = cacheBase;
        _accessControlConfig = accessControlConfig;
    }

    #endregion

    #region Fields

    private readonly IRepository<Page> _pageRepository;
    private readonly IWorkContextAccessor _workContextAccessor;
    private readonly IAclService _aclService;
    private readonly IMediator _mediator;
    private readonly ICacheBase _cacheBase;
    private readonly AccessControlConfig _accessControlConfig;

    #endregion

    #region Methods

    /// <summary>
    ///     Gets a page
    /// </summary>
    /// <param name="pageId">The page identifier</param>
    /// <returns>Page</returns>
    public virtual Task<Page> GetPageById(string pageId)
    {
        var key = string.Format(CacheKey.PAGES_BY_ID_KEY, pageId);
        return _cacheBase.GetAsync(key, () => _pageRepository.GetByIdAsync(pageId));
    }

    /// <summary>
    ///     Gets a page
    /// </summary>
    /// <param name="systemName">The page system name</param>
    /// <param name="storeId">Store identifier; pass 0 to ignore filtering by store and load the first one</param>
    /// <returns>Page</returns>
    public virtual async Task<Page> GetPageBySystemName(string systemName, string storeId = "")
    {
        if (string.IsNullOrEmpty(systemName))
            return null;

        var key = string.Format(CacheKey.PAGES_BY_SYSTEMNAME, systemName, storeId);
        return await _cacheBase.GetAsync(key, async () =>
        {
            var query = from p in _pageRepository.Table
                select p;

            query = query.Where(t => t.SystemName.ToLower() == systemName.ToLower());
            query = query.OrderBy(t => t.Id);
            var pages = await Task.FromResult(query.ToList());
            if (!string.IsNullOrEmpty(storeId)) pages = pages.Where(x => _aclService.Authorize(x, storeId)).ToList();
            return pages.FirstOrDefault();
        });
    }

    /// <summary>
    ///     Gets all pages
    /// </summary>
    /// <param name="storeId">Store identifier; pass "" to load all records</param>
    /// <param name="ignoreAcl"></param>
    /// <returns>Pages</returns>
    public virtual async Task<IList<Page>> GetAllPages(string storeId, bool ignoreAcl = false)
    {
        var key = string.Format(CacheKey.PAGES_ALL_KEY, storeId, ignoreAcl);
        return await _cacheBase.GetAsync(key, async () =>
        {
            var query = from p in _pageRepository.Table
                select p;

            query = query.OrderBy(t => t.DisplayOrder).ThenBy(t => t.SystemName);

            if ((string.IsNullOrEmpty(storeId) || _accessControlConfig.IgnoreStoreLimitations) &&
                (ignoreAcl || _accessControlConfig.IgnoreAcl)) return await Task.FromResult(query.ToList());
            {
                if (!ignoreAcl && !_accessControlConfig.IgnoreAcl)
                {
                    var allowedCustomerGroupsIds = _workContextAccessor.WorkContext.CurrentCustomer.GetCustomerGroupIds();
                    query = from p in query
                        where !p.LimitedToGroups || allowedCustomerGroupsIds.Any(x => p.CustomerGroups.Contains(x))
                        select p;
                }

                //Store acl
                if (string.IsNullOrEmpty(storeId) || _accessControlConfig.IgnoreStoreLimitations)
                    return await Task.FromResult(query.ToList());
                query = from p in query
                    where !p.LimitedToStores || p.Stores.Contains(storeId)
                    select p;

                query = query.OrderBy(t => t.SystemName);
            }
            return await Task.FromResult(query.ToList());
        });
    }

    /// <summary>
    ///     Inserts a page
    /// </summary>
    /// <param name="page">Page</param>
    public virtual async Task InsertPage(Page page)
    {
        ArgumentNullException.ThrowIfNull(page);

        await _pageRepository.InsertAsync(page);

        //cache
        await _cacheBase.RemoveByPrefix(CacheKey.PAGES_PATTERN_KEY);
        //event notification
        await _mediator.EntityInserted(page);
    }

    /// <summary>
    ///     Updates the page
    /// </summary>
    /// <param name="page">Page</param>
    public virtual async Task UpdatePage(Page page)
    {
        ArgumentNullException.ThrowIfNull(page);

        await _pageRepository.UpdateAsync(page);

        //cache
        await _cacheBase.RemoveByPrefix(CacheKey.PAGES_PATTERN_KEY);

        //event notification
        await _mediator.EntityUpdated(page);
    }

    /// <summary>
    ///     Deletes a page
    /// </summary>
    /// <param name="page">Page</param>
    public virtual async Task DeletePage(Page page)
    {
        ArgumentNullException.ThrowIfNull(page);

        await _pageRepository.DeleteAsync(page);

        //cache
        await _cacheBase.RemoveByPrefix(CacheKey.PAGES_PATTERN_KEY);
        //event notification
        await _mediator.EntityDeleted(page);
    }

    #endregion
}